google.golang.org/grpc.serverStream.s (field)
18 uses
google.golang.org/grpc (current package)
server.go#L1503: s: stream,
server.go#L1589: t.WriteStatus(ss.s, st)
server.go#L1643: t.WriteStatus(ss.s, appStatus)
server.go#L1646: Trailer: ss.s.Trailer(),
server.go#L1661: err = t.WriteStatus(ss.s, statusOK)
server.go#L1664: Trailer: ss.s.Trailer(),
stream.go#L1505: s *transport.Stream
stream.go#L1544: return ss.s.SetHeader(md)
stream.go#L1553: err = ss.t.WriteHeader(ss.s, md)
stream.go#L1555: h, _ := ss.s.Header()
stream.go#L1574: ss.s.SetTrailer(md)
stream.go#L1593: ss.t.WriteStatus(ss.s, st)
stream.go#L1616: if err := ss.t.Write(ss.s, hdr, payload, &transport.Options{Last: false}); err != nil {
stream.go#L1621: h, _ := ss.s.Header()
stream.go#L1639: sh.HandleRPC(ss.s.Context(), outPayload(false, m, data, payload, time.Now()))
stream.go#L1661: ss.t.WriteStatus(ss.s, st)
stream.go#L1677: if err := recv(ss.p, ss.codec, ss.s, ss.dc, m, ss.maxReceiveMessageSize, payInfo, ss.decomp); err != nil {
stream.go#L1694: sh.HandleRPC(ss.s.Context(), &stats.InPayload{